"""
RDD 成员方法 filer实现过滤，留下想要的数据
"""
from my_utils import spark_util

sc = spark_util.get_spark_context()

# 添加数据并对数据进行过滤，取出所有的偶数
filter_rdd = sc.parallelize([1, 2, 3, 4, 5]).filter(lambda x: x % 2 == 0)

# 打印结果
print(filter_rdd.collect())

# 关闭spark
sc.stop()
